package org.codefilarete.stalactite.sql.result;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.NoSuchElementException;

import org.codefilarete.stalactite.sql.test.DatabaseIntegrationTest;
import org.codefilarete.tool.collection.Arrays;
import org.junit.jupiter.api.Test;

import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatCode;

/**
 * Database integration test template for {@link ResultSetIterator}, see implementations in sql-adapter submodules
 *
 * @author Guillaume Mary
 */
public abstract class ResultSetIteratorITTest extends DatabaseIntegrationTest {
	
	@Test
	void hasNext_emptyResultSet() throws SQLException {
		Connection connection = connectionProvider.giveConnection();
		ensureTable(connection);
		
		PreparedStatement selectStmnt = connection.prepareStatement("select name from Toto");
		ResultSet selectStmntRs = selectStmnt.executeQuery();
		
		ResultSetIterator<String> resultSetIterator = new ResultSetIterator<String>(selectStmntRs) {
			@Override
			public String convert(ResultSet rs) throws SQLException {
				return rs.getString("name");
			}
		};
		assertThat(resultSetIterator.hasNext()).isFalse();
	}
	
	@Test
	void hasNext_filledResultSet() throws SQLException {
		Connection connection = connectionProvider.giveConnection();
		ensureTable(connection);

		PreparedStatement insertDataStmnt = connection.prepareStatement("insert into Toto(name) values ('a'), ('b'), ('c')");
		insertDataStmnt.execute();
		
		PreparedStatement selectStmnt = connection.prepareStatement("select name from Toto");
		ResultSet selectStmntRs = selectStmnt.executeQuery();
		
		ResultSetIterator<String> resultSetIterator = new ResultSetIterator<String>(selectStmntRs) {
			@Override
			public String convert(ResultSet rs) throws SQLException {
				return rs.getString("name");
			}
		};
		assertThat(resultSetIterator.hasNext()).isTrue();
		resultSetIterator.next();
		assertThat(resultSetIterator.hasNext()).isTrue();
		resultSetIterator.next();
		assertThat(resultSetIterator.hasNext()).isTrue();
		resultSetIterator.next();
		assertThat(resultSetIterator.hasNext()).isFalse();
	}
	
	@Test
	void next_withoutCallToHasNext_throwsNoSuchElementException() throws SQLException {
		Connection connection = connectionProvider.giveConnection();
		ensureTable(connection);
		
		PreparedStatement insertDataStmnt = connection.prepareStatement("insert into Toto(name) values ('a'), ('b'), ('c')");
		insertDataStmnt.execute();
		
		PreparedStatement selectStmnt = connection.prepareStatement("select name from Toto");
		ResultSet selectStmntRs = selectStmnt.executeQuery();
		
		ResultSetIterator<String> resultSetIterator = new ResultSetIterator<String>(selectStmntRs) {
			@Override
			public String convert(ResultSet rs) throws SQLException {
				return rs.getString("name");
			}
		};
		// No call to hasNext() throws NoSuchElementException
		assertThatCode(resultSetIterator::next).isInstanceOf(NoSuchElementException.class);
		
		// Multiple calls to next() without calling hasNext() throw NoSuchElementException
		assertThat(resultSetIterator.hasNext()).isTrue();
		resultSetIterator.next();
		assertThatCode(resultSetIterator::next).isInstanceOf(NoSuchElementException.class);
	}
	
	@Test
	void convert() throws SQLException {
		Connection connection = connectionProvider.giveConnection();
		ensureTable(connection);
		
		PreparedStatement insertDataStmnt = connection.prepareStatement("insert into Toto(name) values ('a'), ('b'), ('c')");
		insertDataStmnt.execute();
		
		PreparedStatement selectStmnt = connection.prepareStatement("select name from Toto");
		ResultSet selectStmntRs = selectStmnt.executeQuery();
		
		ResultSetIterator<String> resultSetIterator = new ResultSetIterator<String>(selectStmntRs) {
			@Override
			public String convert(ResultSet rs) throws SQLException {
				return rs.getString("name");
			}
		};
		assertThat(resultSetIterator.convert()).isEqualTo(Arrays.asList("a", "b", "c"));
	}
	
	private void ensureTable(Connection connection) throws SQLException {
		PreparedStatement createTableStmnt = connection.prepareStatement("create table Toto(name VARCHAR(10))");
		createTableStmnt.execute();
	}
}
